package com.shell.customer.invitation.rx;

import com.shell.customer.base.dao.CusInvtDao;
import com.shell.customer.invitation.InvtEvent;
import com.shell.customer.po.CusInvt;
import com.shell.framework.rx.OnErrorNotImplementedSubscriber;
import java.util.List;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@Component
public class UpdateInvtTimesSubscriber extends OnErrorNotImplementedSubscriber<InvtEvent> {
	@Autowired
	private CusInvtDao cusInvtDao;

	public void onApplicationEvent(InvtEvent event) {
		List<CusInvt> cusInvts = event.getCusInvts();
		for (CusInvt cusInvt : cusInvts) {
			cusInvt.setInviterTimes(Integer.valueOf(cusInvt.getInviterTimes().intValue() + 1));
			this.cusInvtDao.updateByPrimaryKey(cusInvt);
		}
	}
}
